console.log(`${__filename}:1`);

const promiseMysql = require("promise-mysql");

const hostRw = process.env.AWS_RDS_HOST_RW;
const hostRo = process.env.AWS_RDS_HOST_RO;
const user = process.env.AWS_RDS_USER;
const password = process.env.AWS_RDS_PASSWORD;
const database = process.env.AWS_RDS_DATABASE;

const createPool = host => {
    let pool;
    const poolPromise = async () => {
        if (pool)
            return pool;

        console.log(`createPool\t${host}`);
        return pool = promiseMysql.createPool({
            host,
            user,
            password,
            database,
            ssl: {
                rejectUnauthorized: false,
                minVersion: 'TLSv1',
            },
            typeCast: function castField(field, useDefaultTypeCasting) {
                if ((field.type === "BIT") && ( /*MySQL*/ field.length === 1 || /*MariaDB*/ field.columnLength === 1)) {
                    const bytes = field.buffer();
                    if (bytes === null)
                        return null;

                    return bytes[0] === 1;
                }
                return useDefaultTypeCasting();
            },
        });
    };

    return {
        getPoolPromise: async () => await poolPromise(),
        async getConnection() {
            return (await poolPromise()).getConnection(...arguments)
        },
        async query() {
            return (await poolPromise()).query(...arguments)
        },
        async selectOne() {
            const array = await (await poolPromise()).query(...arguments);
            return array?.[0];
        },
        selectOneViaConn: async (conn, ...rest) => {
            const array = await conn.query(...rest);
            return array?.[0];
        },
    };
};

module.exports = {
    rw: createPool(hostRw),
    ro: createPool(hostRo),
};